"""Project pipelines."""

from kedro.framework.project import find_pipelines
from kedro.pipeline import Pipeline

# 用于注册和管理项目中的所有 Pipeline
def register_pipelines() -> dict[str, Pipeline]:
    """Register the project's pipelines.

    Returns:
        A mapping from pipeline names to ``Pipeline`` objects.
    """
    #自动发现项目里的所有 Pipeline 并用目录名作为 pipeline 的名字（比如 data_science）
    pipelines = find_pipelines()
    # 把所有 Pipeline 合并为一个默认管道, Kedro 支持 __default__，可以一次性运行所有已注册的 Pipeline。
    pipelines["__default__"] = sum(pipelines.values())
    return pipelines
